package com.sqllog.admin.sql.mapper;

import com.sqllog.admin.sql.entity.CanalClientConsumerLog;
import org.apache.ibatis.annotations.Param;

import java.util.List;

/**
 * canal 客户端消费日志
 *
 * @author chennengcheng
 * @date 2022-02-09 11:11
 * @remark
 */
public interface CanalClientConsumerLogMapper {

    List<CanalClientConsumerLog> selectByClientId(@Param("clientId")String clientId);

    int insert(CanalClientConsumerLog canalClientConsumerLog);

    int deleteByCreateDate(@Param("createDate")String createDate);
}
